package com.yf.demo.disruptor;

import java.util.Random;

public class DisruptorDemo {
	
	public static void main(String[] args) throws Exception {
		DisruptorUtils.start();
		for(int i= 0;i<1000;i++){
			DisruptorUtils.produce("你好!"+i);
			Thread.sleep(new Random().nextInt(10));
			System.err.println("生产完毕:你好!"+i);
		}
		DisruptorUtils.shutdown();
	}
}
